/*
 * Copyright (C) 2005-2011 MaNGOS <http://www.getmangos.com/>
 *
 * Copyright (C) 2008-2011 Trinity <http://www.trinitycore.org/>
 *
 * Copyright (C) 2010-2011 ArkCORE <http://www.arkania.net/>
 *
 * This program is free software; you can redistribute it and/or modify
 * it under the terms of the GNU General Public License as published by
 * the Free Software Foundation; either version 2 of the License, or
 * (at your option) any later version.
 *
 * This program is distributed in the hope that it will be useful,
 * but WITHOUT ANY WARRANTY; without even the implied warranty of
 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
 * GNU General Public License for more details.
 *
 * You should have received a copy of the GNU General Public License
 * along with this program; if not, write to the Free Software
 * Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA
 */

/** \file
 \ingroup Trinityd
 */

#include "Common.h"
#include "Config.h"
#include "Log.h"
#include "RARunnable.h"
#include "World.h"

#include <ace/Reactor_Impl.h>
#include <ace/TP_Reactor.h>
#include <ace/Dev_Poll_Reactor.h>
#include <ace/Acceptor.h>
#include <ace/SOCK_Acceptor.h>

#include "RASocket.h"

RARunnable::RARunnable() :
		m_Reactor(NULL) {
	ACE_Reactor_Impl* imp = 0;

#if defined (ACE_HAS_EVENT_POLL) || defined (ACE_HAS_DEV_POLL)

	imp = new ACE_Dev_Poll_Reactor();

	imp->max_notify_iterations (128);
	imp->restart (1);

#else

	imp = new ACE_TP_Reactor();
	imp->max_notify_iterations(128);

#endif

	m_Reactor = new ACE_Reactor(imp, 1);
}

RARunnable::~RARunnable() {
	delete m_Reactor;
}

void RARunnable::run() {
	if (!sConfig->GetBoolDefault("Ra.Enable", false))
		return;

	ACE_Acceptor<RASocket, ACE_SOCK_ACCEPTOR> acceptor;

	uint16 raport = sConfig->GetIntDefault("Ra.Port", 3443);
	std::string stringip = sConfig->GetStringDefault("Ra.IP", "0.0.0.0");

	ACE_INET_Addr listen_addr(raport, stringip.c_str());

	if (acceptor.open(listen_addr, m_Reactor) == -1) {
		sLog->outError("Trinity RA can not bind to port %d on %s", raport,
				stringip.c_str());
		return;
	}

	sLog->outString("Starting Trinity RA on port %d on %s", raport,
			stringip.c_str());

	while (!World::IsStopped()) {
		// don't be too smart to move this outside the loop
		// the run_reactor_event_loop will modify interval
		ACE_Time_Value interval(0, 100000);

		if (m_Reactor->run_reactor_event_loop(interval) == -1)
			break;
	}

	sLog->outStaticDebug("Trinity RA thread exiting");
}
